-
Notifications
You must be signed in to change notification settings - Fork 3.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add segment merge time as a metric #1770
Conversation
@@ -538,6 +538,9 @@ public void doRun() | |||
cleanShutdown = false; | |||
abandonSegment(truncatedTime, sink); | |||
} | |||
} finally { | |||
metrics.incrementPersistTimeMillis(mergeStopwatch.elapsed(TimeUnit.MILLISECONDS)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this also includes segment publish time, it might be worthwhile to only count actual merge time if handoff can take a while?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
moved it to exclude segment publish time.
How viable is it to add CPU time in addition to wall-time? |
abba6c2
to
790f928
Compare
@drcrallen added cpuTime for both persist and merge operations. please have a look again. |
790f928
to
d426562
Compare
emitter.emit(builder.build("ingest/merge/time", metrics.mergeTimeMillis() - previous.mergeTimeMillis())); | ||
emitter.emit(builder.build("ingest/merge/cpu", metrics.mergeCpuTime() - previous.mergeCpuTime())); | ||
emitter.emit(builder.build("ingest/persist/cpu", metrics.persistCpuTime() - previous.persistCpuTime())); | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
minor nit, unnecessary empty lines
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
removed empty lines.
e2f8717
to
795d09f
Compare
|
||
emitter.emit(builder.build("ingest/merge/time", metrics.mergeTimeMillis() - previous.mergeTimeMillis())); | ||
emitter.emit(builder.build("ingest/merge/cpu", metrics.mergeCpuTime() - previous.mergeCpuTime())); | ||
emitter.emit(builder.build("ingest/persist/cpu", metrics.persistCpuTime() - previous.persistCpuTime())); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this needs documentation update.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
also, it appears we will be publishing these metrics whether or not cpu time is supported , so should document that if user sees a value of 0 then that means its just not supported on the jvm
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done. added docs.
Add merge and persist cpu time Fix typo review comment move cpu time measuring to VMUtils review comments.
795d09f
to
7cecc55
Compare
LGTM |
👍 @xvrl are your comments addressed? |
Add segment merge time as a metric
Backport #1770 - Add segment merge time as a metric
Adds these metrics -